type ABCStreamInterceptor struct {
	MsgRcvCount  int
	MsgSendCount int
            MsgChan 	 chan int
}

func (s *ABCStreamInterceptor) Send(callData *CallData) (*dynamic.Message, error) {
	defer func() { s.MsgSendCount++ }()
	switch s.MsgSendCount {
	case 0:
		return dynamic.AsDynamicMessage(&exampleapi.Request{
			Num: 1,
		})
	case 1:
		num := <-s.MsgChan
		return dynamic.AsDynamicMessage(&exampleapi.Request{
			Num: num,
		})
	default:
		return nil, fmt.Errorf("unknown msg send")
	}
}

func (s *ABCStreamInterceptor) Recv(msg *dynamic.Message, err error) error {
	if msg == nil {
		return err
	}
	s.MsgRcvCount++

	reply := exampleapi.Response{}
	err = msg.ConvertTo(reply)
	if err != nil {
		return err
	}

	switch s.MsgRcvCount {
	case 0:
		s.MsgChan <- reply.Num
		return nil
	case 1:
		return runner.ErrEndStream
	default:
		return fmt.Errorf("unknown msg recv")
	}
}

WithStreamInterceptorProviderFunc(func NewABCInterceptor() StreamInterceptor {
	return &ABCStreamInterceptor{
			MsgChan:          make(chan exampleapi.response, 1),
		}
	}
})`